package org.zhadoop.streaming.serde;

import java.io.Serializable;

import org.zhadoop.streaming.config.StreamingConfig;
import org.zhadoop.streaming.exception.StreamingException;

/**
 * 系统的反序列化接口
 * 在从输入流中读人输入的时候，要进行反序列化，才能被系统识别
 * 另外，反序列化还可能被应用于节点之间的数据传输
 * @author zwd
 *
 */
public interface StreamSerDe extends Serializable{
	
	/**
	 * 设置配置属性
	 * 编译是运行
	 * @param conf
	 * @throws StreamingException
	 */
	void setConfig(StreamingConfig conf) throws StreamingException;
	
	/**
	 * 获取配置属性
	 * @return
	 */
	StreamingConfig getConfig();
	
	
}
